package com.ycrlkj.android.modulespublic.common.net.exception;

import io.reactivex.functions.Consumer;

/**
 * 请求错误处理消费者
 * 自定义一个类(ErrorConsumer) 继承 Consumer, 做为请求订阅 subscribe 的第二个参数
 */
public abstract class ErrorConsumer implements Consumer<Throwable> {

    @Override
    public void accept(Throwable exception) throws Exception {
        //调用错误处理方法
        error(ApiException.exception2ApiException(exception));
    }

    protected abstract void error(ApiException e);
}